# coding:utf-8
r''' 传鸿组态mysql处理器
 * @ 作  者: 阿拉丁矿工 黄传鸿 <hchhyzc@foxmail.com>
'''
# ====================================================================|引入包
import pymysql
import os
import sys
import json
import datetime


# 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
# 传鸿组态mysql驱动类
# 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓

class HmysqlClass:
    '''传鸿组态mysql驱动类'''

    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
    # 库;表; 创建_删除
    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓

    # ——————————————————————————————————————————————————————————————————————
    # 创建数据库
    # ——————————————————————————————————————————————————————————————————————

    def createDB(self):
        '''创建数据库'''
        # print("\n♈  创建数据库")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()
        try:
            mycursor.execute("CREATE DATABASE chzt")
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚
        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 删除数据库
    # ——————————————————————————————————————————————————————————————————————

    def dropDB(self):
        '''删除数据库'''
        # print("\n♈  删除数据库")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立数据库
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """DROp DATABASE chzt"""
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            mydb.commit()  # 提交到数据库执行
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚
        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 创建表 通道
    # ——————————————————————————————————————————————————————————————————————
    def createChannelTable(self):
        '''创建通道表'''
        # print("\n♈  创建通道表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """
        CREATE TABLE t_channel(
            id INT(6) NOT NULL PRIMARY KEY AUTO_INCREMENT,
            `channelDescr` VARCHAR(300) NULL COMMENT '描述',
            `channelId` VARCHAR(200) NULL COMMENT '通道id',
            `channelType` VARCHAR(200) NULL COMMENT '通道类型',
            `channelIpAddr` VARCHAR(200) NULL COMMENT 'ip地址',
            `channelCPUSlot` VARCHAR(200) NULL COMMENT 'CPU插槽',
            `UpdateTime` timestamp not null default CURRENT_TIMESTAMP COMMENT '更新时间'
            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
        """
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚

        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 删除表 通道
    # ——————————————————————————————————————————————————————————————————————
    def dropChannelTable(self):
        '''删除通道表'''
        # print("\n♈  删除通道表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库删除通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = "DROP TABLE t_channel"
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            mydb.commit()  # 提交到数据库执行
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚
        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 创建表 设备
    # ——————————————————————————————————————————————————————————————————————
    def createEquipTable(self):
        '''创建设备表'''
        # print("\n♈  创建设备表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt"  # 数据库
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """
        CREATE TABLE t_equip(
            id INT(6) NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
            `equipDataDescr` VARCHAR(200) NULL COMMENT '说明',
            `equipDataLabel` VARCHAR(200) NULL COMMENT '标签名',
            `equipDataId` VARCHAR(100) NULL COMMENT '设备id',
            `equipDataType` VARCHAR(100) NULL COMMENT '设备数据类型',
            `equipDataRW` VARCHAR(100) NULL COMMENT '读写状态',
            `channelId` VARCHAR(100) NULL COMMENT '通道id',
            `equipDataVal` VARCHAR(100) NULL COMMENT '变量值',
            `UpdateTime` timestamp not null default CURRENT_TIMESTAMP COMMENT '更新时间'
            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
        """
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚

        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 删除表 设备
    # ——————————————————————————————————————————————————————————————————————
    def dropEuipmentTable(self):
        '''删除设备表'''
        # print("\n♈  删除设备表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库删除通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """DROp TABLE t_equip"""
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            mydb.commit()  # 提交到数据库执行
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚
        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 创建表 历史记录 history
    # ——————————————————————————————————————————————————————————————————————
    def createHistoryTable(self):
        '''创建 历史记录表'''
        # print("\n♈  创建 历史记录表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt"  # 数据库
            # charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """
        CREATE TABLE t_history(
            id INT(6) NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
            `equipDataDescr` VARCHAR(100) NULL COMMENT '说明',
            `equipDataLabel` VARCHAR(100) NULL COMMENT '标签',
            `equipDataId` VARCHAR(100) NULL COMMENT '键',
            `equipDataVal` VARCHAR(50) NULL COMMENT '值',
            `UpdateTime` timestamp not null default CURRENT_TIMESTAMP COMMENT '更新时间'
            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
        """
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚

        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 删除表 历史记录 history
    # ——————————————————————————————————————————————————————————————————————
    def dropHistoryTable(self):
        '''删除 历史记录表'''
        # print("\n♈  删除 历史记录表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库删除表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """DROP TABLE t_history"""
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            mydb.commit()  # 提交到数据库执行
            # print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚
        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 删除视图 通道详情
    # ——————————————————————————————————————————————————————————————————————
    def dropChannelDetailsView(self):
        '''创建 通道详情视图'''
        # print("\n♈  创建 通道详情视图")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt"  # 数据库
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """ DROP VIEW v_channel_detial;"""
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚

        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 创建视图 通道详情
    # ——————————————————————————————————————————————————————————————————————
    def createChannelDetailsView(self):
        '''创建视图 通道详情'''
        # print("\n♈  创建视图 通道详情")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt"  # 数据库
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 建立通道表
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        # SQL 查询语句
        myQuery = """
            CREATE VIEW v_channel_details 
            AS 
            SELECT
            	t_channel.ChName,
            	t_channel.ChId,
            	t_channel.ChType,
            	t_channel.IpAddr,
            	t_channel.CPUSlot,
            	t_equip.equipDataDescr,
            	t_equip.equipDataLabel,
            	t_equip.equipDataId,
            	t_equip.equipDataRW,
            	t_equip.equipDataVal
            FROM
            	t_channel
            INNER JOIN t_equip ON t_channel.ChId = t_equip.ChId
            ORDER BY
            	t_channel.ChType ASC ;
        """
        try:
            mycursor.execute(myQuery)  # 执行SQL语句
            print(mycursor.rowcount)
        except:
            mydb.rollback()  # 如果发生错误则回滚

        mycursor.close()  # 先关闭游标
        mydb.close()  # 再关闭数据库连接

    # ——————————————————————————————————————————————————————————————————————
    # 创建 告警表 alarm
    # ——————————————————————————————————————————————————————————————————————

    # ——————————————————————————————————————————————————————————————————————
    # 删除 告警表 alarm
    # ——————————————————————————————————————————————————————————————————————

    # ——————————————————————————————————————————————————————————————————————
    # 创建 开停机表 run
    # ——————————————————————————————————————————————————————————————————————

    # ——————————————————————————————————————————————————————————————————————
    # 删除 开停机表 run
    # ——————————————————————————————————————————————————————————————————————

    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
    # 数据; 添加
    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓

    # ——————————————————————————————————————————————————————————————————————
    # 添加到通道表
    # ——————————————————————————————————————————————————————————————————————

    def addToChannel(self, Channels):
        '''添加到通道表'''
        # print("\n♈  添加到通道表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()

        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 变量转储
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        for item in Channels:
            # print("  ★ 变量转储")
            channelDescr = str(item['label'])
            channelId = str(item['key'])
            channelType = str(item['type'])
            channelIpAddr = str(item['ip_addr'])
            channelCPUSlot = str(item['cpu_slot'])

            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            #   ★ 向通道表中填充数据
            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            # print("  ▶ -----------------------------------| 向[通道表]中填充数据")
            # print('♒ 转换值:', Name, ChId, IpAddr, CPUSlot)
            # SQL 查询语句
            myQuery = """INSERT INTO t_channel (channelDescr, channelId, channelType, channelIpAddr, channelCPUSlot) VALUES (%s,%s,%s,%s,%s)"""
            val = (channelDescr, channelId, channelType, channelIpAddr, channelCPUSlot)

            try:
                mycursor.execute(myQuery, val)  # 执行sql语句
                mydb.commit()  # 提交到数据库执行
                # print("  提交结果:", mycursor.rowcount)
            except:
                # print("  错误结果:", mycursor.rowcount)
                mydb.rollback()  # 如果发生错误则回滚

    # ——————————————————————————————————————————————————————————————————————
    # 添加到设备表
    # ——————————————————————————————————————————————————————————————————————

    def addToEquip(self, EquipData):
        '''添加到设备表'''
        print("\n♈ 添加到设备表")
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 数据库设置
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        mydb = pymysql.connect(
            host="localhost",  # 数据库主机地址
            user="root",  # 数据库用户名
            passwd="hciot",  # 数据库密码
            db="chzt",  # 数据库
            charset='utf8'
        )
        # 获取游标
        mycursor = mydb.cursor()
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        #   ★ 变量转储
        # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
        for item in EquipData:
            # print("  ★ 变量转储")
            # print(item)
            equipDataId = str(item['equipDataId'])
            equipDataDescr = str(item['equipDataDescr'])
            equipDataLabel = str(item['equipDataLabel'])
            equipDataType = str(item['equipDataType'])
            equipDataRW = str(item['equipDataRW'])
            channelId = str(item['channelId'])
            equipDataVal = str(item['equipDataVal'])
            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            #   ★ 通过通道id查询通道类型
            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            #   ★ 向通道表中填充数据
            # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            # print("  ▶ -----------------------------------向表中填充数据")
            # print('♒ 转换值:', equipDataId, equipDataDescr, equipDataLabel, equipDataType, equipDataRW, channelId, equipDataVal)
            # SQL 查询语句
            myQuery = """INSERT INTO t_equip (equipDataId, equipDataDescr, equipDataLabel, equipDataType, equipDataRW, channelId, equipDataVal) VALUES (%s,%s,%s,%s,%s,%s,%s)"""
            val = (equipDataId, equipDataDescr, equipDataLabel, equipDataType, equipDataRW, channelId, equipDataVal)
            try:
                mycursor.execute(myQuery, val)  # 执行sql语句
                mydb.commit()  # 提交到数据库执行
                # print("  提交结果:", mycursor.rowcount)
            except:
                # print("  错误结果:", mycursor.rowcount)
                mydb.rollback()  # 如果发生错误则回滚

    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
    # 数据; 更新
    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓

    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
    # 数据; 查询
    # 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓


# 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓
# 主函数
# 〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓〓


def main():
    '''主函数'''
    print("传鸿组态mysql处理器")


if __name__ == "__main__":
    main()
